package com.seedog.mq.exception;

/**
 * 当消费者接收消息时发生错误抛出的异常
 */
public class ConsumerException extends MessageQueueException {
    private static final long serialVersionUID = 1L;
    private static final int DEFAULT_ERROR_CODE = 500;
    
    public ConsumerException(String message) {
        super(DEFAULT_ERROR_CODE, "Consumer error: " + message);
    }
    
    public ConsumerException(String message, Throwable cause) {
        super(DEFAULT_ERROR_CODE, "Consumer error: " + message, cause);
    }
}